public Connection createConnection() throws SQLException {

      final Properties info = new Properties();

      for (Map.Entry<String, String> entry : map.entrySet()) {

        info.setProperty(entry.getKey(), entry.getValue());

      }

      Connection connection =

          DriverManager.getConnection("jdbc:calcite:", info);

      for (ConnectionPostProcessor postProcessor : postProcessors) {

        connection = postProcessor.apply(connection);

      }

      return connection;

    }

https://apache.googlesource.com/kafka/+/trunk/examples/src/main/java/kafka/examples/Producer.java

    public void init(BundleContext context, DependencyManager manager) throws Exception {

        manager.add(createComponent()

            .setInterface(Servlet.class.getName(), null)

            .setImplementation(DeploymentServlet.class)

            .add(createConfigurationDependency().setPropagate(true).setPid(DEPLOYMENT_PID))

            .add(createServiceDependency().setService(StreamGenerator.class).setRequired(true))

            .add(createServiceDependency().setService(DeploymentProvider.class).setRequired(true))

            .add(createServiceDependency().setService(DeploymentProcessor.class).setRequired(false).setCallbacks("addProcessor", "removeProcessor"))

            .add(createServiceDependency().setService(LogService.class).setRequired(false))

        );

        manager.add(createComponent()

            .setInterface(Servlet.class.getName(), null)

            .setImplementation(AgentDeploymentServlet.class)

            .add(createConfigurationDependency().setPropagate(true).setPid(AGENT_PID))

            .add(createServiceDependency().setService(ConnectionFactory.class).setRequired(true))

            .add(createServiceDependency().setService(LogService.class).setRequired(false))

        );

        

        Properties props = new Properties();

        props.put("pattern", "/*");

        manager.add(createComponent()

            .setInterface(Filter.class.getName(), null)

            .setImplementation(OverloadedFilter.class)

        );

    }